package kafkacli

import (
	"fmt"
	"strconv"

	"github.com/gogf/gf/util/grand"
)

var (
	TopicGetSubDomain  = "TopicGetSubDomain."
	TopicAllLink       = "TopicAllLink."
	TopicDcgo          = "TopicDcgo."
	TopicValidUrlCheck = "TopicValidUrlCheck."
	TopicNewKeyword    = "TopicNewKeyword"
)

func getRandPrefix() string {
	return strconv.Itoa(grand.N(0, 4))
}

func getAllPrefix(topic string) (ret []string) {
	for ii := 0; ii <= 4; ii++ {
		ret = append(ret, topic+strconv.Itoa(ii))
	}
	fmt.Println("ret", ret)
	return
}
